package com.bcdat.bcdatbrace.bacdatKafka.server;

import org.apache.kafka.clients.consumer.ConsumerRecord;

/**
 * @author lsy
 * @version 0.1
 * @date 2019/09/30 15:32
 * kafka消费者
 */
public interface KafkaServer {

    void listen(ConsumerRecord<?,?> record);
}
